package com.qf.air.service;

import org.elasticsearch.action.DocWriteRequest;

import java.io.IOException;
import java.util.List;
import java.util.Map;

/**
 * 封装ES的基本操作
 * @author
 */
public interface ElasticsearchService {


    /**
     * 批量增删改ES操作
     * @param requests
     */
    void bulk(DocWriteRequest...requests) throws IOException;

    /**
     * 查询air索引中的数据count
     * @param parameters
     * @return
     */
    long findAirIndexCount(Map parameters) throws IOException;


    /**
     * 查询air索引中的具体数据
     * @param parameters
     * @return
     */
    List<Map> findAirIndexData(Map parameters) throws IOException;

}
